package com.nami.transport.utils;


public class MsgTimeUtil {

    /**
     * MQ 消息 过期 间隔 3分钟
     */
    public static final Long DELTA = 180L;

    /**
     * 判断mq消息的有效性。是否过期消息，如果过期，不予消费
     * @param currTime
     * @return
     */
    public static boolean isMessageExpired(Long currTime) {
        if (currTime == null) {
            return true;
        }

        return ((System.currentTimeMillis() - currTime) / 1000) > DELTA;
    }


}
